package com.fwmagic.spark.streaming.util

import com.alibaba.druid.pool.DruidDataSource
import java.sql.Connection

object DBUtils {

    var dataSource = new DruidDataSource()// 声明Druid连接池的对象

    dataSource.setDriverClassName("com.mysql.jdbc.Driver") // 设置连接池的数据库驱动
    dataSource.setUrl("jdbc:mysql://localhost:3306/spark_test?useSSL=false&useUnicode=true&characterEncoding=utf8") // 设置数据库的连接地址
    dataSource.setUsername("root") // 设置数据库的用户名
    dataSource.setPassword("123456") // 设置数据库的密码
    dataSource.setInitialSize(5) // 设置连接池的初始大小
    dataSource.setMinIdle(5) // 设置连接池大小的下限
    dataSource.setMaxActive(20) // 设置连接池大小的上限


    def getConnection(): Connection = {
        dataSource.getConnection
    }
}
